package main

import (
	"sync"
)

type Topic struct {
	sync.RWMutex
	name               string
	blockMap           map[string]*Block //topic里的channel
	incomingMsgChan    chan *Message     //数据输入管道
	memoryMsgChan      chan *Message
	messagePumpStarter *sync.Once
	exitChan           chan int
	exitFlag           int32
	messageCount       uint64
}
